package com.zs.rocketmqstream.oldway;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author madison
 * @description
 * @date 2021/7/4 15:18
 */
public interface StreamClient {
    // 这里的名称对应了spring.cloud.stream.rocketmq.bindings.<channelName>
    String OUTPUT = "myOutput";
    String INPUT = "myInput";

    @Input(INPUT)
    SubscribableChannel input();

    @Output(OUTPUT)
    MessageChannel output();
}
